42231e1ab8d674d68dfb3956d5616dc67ac8d4df,ambry-tools/src/main/java/com.github.ambry.tools/admin/DumpData.java,DumpData,dumpActiveBlobsFromIndex,#File#ArrayList#boolean#,405

Before Change



  public void dumpActiveBlobsFromIndex(File indexFileToDump, ArrayList<String> blobList, boolean excludeMiscLogging) {
    ConcurrentHashMap<String, String> blobIdToBlobMessageMap = new ConcurrentHashMap<String, String>();
    if (!excludeMiscLogging) {
      logOutput("Dumping index " + indexFileToDump);
    }
    ActiveBlobStats activeBlobStats = new ActiveBlobStats();
    long totalKeysProcessed =
        dumpActiveBlobsFromIndex(indexFileToDump, blobList, blobIdToBlobMessageMap, excludeMiscLogging,
            activeBlobStats);
    for (String blobId : blobIdToBlobMessageMap.keySet()) {
      logOutput(blobId + " : " + blobIdToBlobMessageMap.get(blobId));
    }
    if (!excludeMiscLogging) {
      logOutput("Total Keys processed for index file " + indexFileToDump + " " + totalKeysProcessed);
      logOutput(
          "Total Put Records for index file " + indexFileToDump + " " + activeBlobStats.getTotalPutRecords().get());
      logOutput("Total Delete Records for index file " + indexFileToDump + " " + activeBlobStats.getTotalDeleteRecords()
          .get());
      logOutput("Total Active Records for index file " + indexFileToDump + " " + blobIdToBlobMessageMap.size());
      logOutput("Total Duplicate Put Records for index file " + indexFileToDump + " " + activeBlobStats
          .getTotalDuplicatePutRecords().get());
      logOutput("Total Delete before Put Or duplicate Delete Records for index file " + indexFileToDump + " "
          + activeBlobStats.getTotalDeleteBeforePutOrDuplicateDeleteRecords().get());
    }
  }

After Change


   */
  public void dumpActiveBlobsFromIndex(File indexFileToDump, ArrayList<String> blobList) {
    ConcurrentHashMap<String, String> blobIdToBlobMessageMap = new ConcurrentHashMap<>();
    logger.trace("Dumping index " + indexFileToDump);
    ActiveBlobStats activeBlobStats = new ActiveBlobStats();
    long totalKeysProcessed =
        dumpActiveBlobsFromIndex(indexFileToDump, blobList, blobIdToBlobMessageMap, activeBlobStats);
    for (String blobId : blobIdToBlobMessageMap.keySet()) {
      logger.info(blobId + " : " + blobIdToBlobMessageMap.get(blobId));
    }
    logger.trace("Total Keys processed for index file " + indexFileToDump + " " + totalKeysProcessed);
    logger.trace(
        "Total Put Records for index file " + indexFileToDump + " " + activeBlobStats.getTotalPutRecords().get(),
        LogLevel.DEBUG);
    logger.trace(
        "Total Delete Records for index file " + indexFileToDump + " " + activeBlobStats.getTotalDeleteRecords().get(),
        LogLevel.DEBUG);
    logger.trace("Total Active Records for index file " + indexFileToDump + " " + blobIdToBlobMessageMap.size());
    logger.trace("Total Duplicate Put Records for index file " + indexFileToDump + " "
        + activeBlobStats.getTotalDuplicatePutRecords().get());
    logger.trace("Total Delete before Put Or duplicate Delete Records for index file " + indexFileToDump + " "
        + activeBlobStats.getTotalDeleteBeforePutOrDuplicateDeleteRecords().get());
  }

  /**